

package com.hazelcast.wan.impl;

import com.hazelcast.config.AbstractWanPublisherConfig;
import com.hazelcast.config.WanReplicationConfig;
import com.hazelcast.wan.WanEvent;
import com.hazelcast.wan.WanPublisher;
import com.hazelcast.wan.WanQueueFullException;

public class WanFullQueuePublisher implements WanPublisher {

    @Override
    public void init(WanReplicationConfig wanReplicationConfig, AbstractWanPublisherConfig wanPublisherConfig) {
    }

    @Override
    public void shutdown() {
    }

    @Override
    public void publishReplicationEvent(WanEvent event) {
    }

    @Override
    public void publishReplicationEventBackup(WanEvent event) {
    }

    @Override
    public void doPrepublicationChecks() {
        throw new WanQueueFullException("WAN event queue is full");
    }
}
